c0c467e781ced532684d4867fd0585dea97ebab4,TwitterScanner/src/com/continuuity/examples/twitter/TwitterProcessor.java,TwitterProcessor,initialize,#,40
Before Change
this.wordCounts = (CounterTable)
getFlowletContext().getDataSetRegistry().registerDataSet(
new CounterTable("wordCounts"));
this.topHashTags = (SortedCounterTable)
getFlowletContext().getDataSetRegistry().registerDataSet(
new SortedCounterTable("topHashTags",
new SortedCounterTable.SortedCounterConfig()));
this.topUsers = (SortedCounterTable)
getFlowletContext().getDataSetRegistry().registerDataSet(
new SortedCounterTable("topUsers",
After Change
@Override
public void initialize() {
this.topHashTags = getFlowletContext().getDataSet(TwitterFlow.topHashTags);
this.topUsers = getFlowletContext().getDataSet(TwitterFlow.topUsers);
this.wordCounts = getFlowletContext().getDataSet(TwitterFlow.wordCounts);
this.hashTagWordAssocs = getFlowletContext().getDataSet(TwitterFlow.hashTagWordAssocs);